package com.akkainaction.tool.eventbus.actor;

import akka.actor.DeadLetter;
import akka.actor.UntypedActor;

public class EventStreamActor extends UntypedActor {
    @Override
    public void onReceive(Object msg) throws Exception {
        if (msg instanceof DeadLetter) {
            DeadLetter deadLetter = (DeadLetter) msg;
            System.out.println("死信消息内容:[" + deadLetter.message() + "] 死信消息发送者:[" + deadLetter.sender() + "] 死信消息接收者:[" + deadLetter.recipient() + "]");
        }
    }
}
